package cn.usts.edu.lesson08;

import cn.usts.util.Utils;


/**
 * 生产者消费之
 * 一个资源被需要,才会被创建,
 * 在生产者和消费者中间还有一个容器作为缓冲,作为一个生产的标志
 *
 *
 * 逻辑没有问题,代码有问题.
 * */

public class ProductorConsumerDemo {
    public static void main(String[] args) {
        Container1 container = new Container1();
        Productor productor = new Productor(container);
        Consumer consumer = new Consumer(container);
        productor.start();
        consumer.start();
    }


}

// 生产者
class Productor extends Thread{
    Container1 container;

    public Productor(Container1 container) {
        this.container = container;
    }

    @Override
    public void run() {
        // 生产100只鸡
        for (int i = 0; i < 100; i++) {
            container.push(new Chicken(i));
            System.out.println("生产了第"+i+"只鸡");
        }
    }
}

// 消费者
class Consumer extends Thread{
    Container1 container;

    public Consumer(Container1 container) {
        this.container = container;
    }

    @Override
    public void run() {
        // 消费100只鸡
        for (int i = 0; i < 100; i++) {
            Chicken chicken = container.pop();
            System.out.println("消费了第--------"+chicken.id+"只鸡");
        }
    }
}


// 生产的产品
class Chicken{
    int id;// 产品编号

    public Chicken(int id) {
        this.id = id;
    }
}


// 容器 缓冲
class Container1 extends Utils {

    // 容器
    Chicken[]  chickens = new Chicken[10];//默认可以放10只鸡

    int count=0;//用来计数


    // 把鸡放到容器中
    public synchronized void push(Chicken chicken){
        // 如果数量达到容器的最大数量,停止生产
        if (chickens.length==count){
            try {
                System.out.println(count+"---------------------");
                this.wait();// 容器满了通知生产者等待
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        // 如果没有达到容器数量,就生产

        chickens[count] = chicken;//把鸡放到容器中
        count++;//容器数量加1

        this.notifyAll();//全都唤醒

    }

    // 消费者消费鸡
    public synchronized Chicken pop(){
        // 判断容器中有么有鸡
        if (count==0){
            try {
                this.wait(); // 通知消费者等待
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        // 有鸡
        count--;
        Chicken chicken = chickens[count]; // 有bug
        this.notify();//通知消费者消费
        return chicken;



    }

}




